952de60aec6abb295d5285c3e4474a04014b1038,qpid-jms-client/src/test/java/org/apache/qpid/jms/JmsSessionTest.java,JmsSessionTest,testCreateSharedConsumer,#,338
Before Change
public void testCreateSharedConsumer() throws Exception {
JmsSession session = (JmsSession) connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
try {
session.createSharedConsumer(session.createTopic("test"), "subscription");
fail("Should fail until implemented.");
} catch (JMSException ex) {}
}
After Change
public void testCreateSharedConsumer() throws Exception {
JmsSession session = (JmsSession) connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Topic topic = session.createTopic("test");
JmsMessageConsumer consumer = (JmsMessageConsumer) session.createSharedConsumer(topic, "subscription");
assertNotNull(consumer);
assertNull("unexpected selector", consumer.getMessageSelector());